package com.we.flink.userlabelplatform.table;

import java.sql.Timestamp;

public class TableTieCardRiskTag {
    public static final String KFKTABLE = "fdm.hhl01_tie_card_risk_tag";
    public static final String QUERYSQL =
            "select uid, "
                    + "if(show_valid_date is null, TIMESTAMP '1970-01-01 08:00:00.000000', show_valid_date) as show_valid_date, "
                    + "update_time from "
                    + KFKTABLE
                    + " where uid is not null "
                    + "and update_time is not null";

    public long uid;
    public Timestamp show_valid_date;
    public Timestamp update_time;

    public TableTieCardRiskTag() {}

    public TableTieCardRiskTag(long uid, Timestamp show_valid_date, Timestamp update_time) {
        this.uid = uid;
        this.show_valid_date = show_valid_date;
        this.update_time = update_time;
    }

    public long getUid() {
        return uid;
    }

    public Timestamp getShow_valid_date() {
        return show_valid_date;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }
}
